package bold.module.zk.curator;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.junit.Before;
import org.junit.Test;

public class ZkCluster {
    CuratorFramework curatorFramework;

    @Before
    public void init() {
        curatorFramework = CuratorFrameworkFactory.builder()
                .connectString("127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183")
//                .connectString("127.0.0.1:2183")
                .retryPolicy(new ExponentialBackoffRetry(1000, 3))
                .connectionTimeoutMs(15 * 1000) //连接超时时间，默认15秒
                .sessionTimeoutMs(60 * 1000) //会话超时时间，默认60秒   todo 这个时间就是 临时节点的删除时间
//                .namespace("arch") //设置命名空间
                .build();
        curatorFramework.start();
    }

    @Test
    public void t1() throws Exception {
        curatorFramework.create().forPath("/1");
        curatorFramework.create().forPath("/2");
    }

}
